// mysql的辅助类
// 减少mysql数据库交互流程的编写
var mysql = require("mysql");

module.exports = {
    query: function (sqlStr,sucess,fail) {
        // 构造函数
        var con = mysql.createConnection({
            host: "localhost",
            port: 3306,
            user: "root",
            password: '123456',
            database: "bh3data",
        })
         // 建立连接
        con.connect(function (err) {
            if (!err) {
                // 执行sql
                con.query(sqlStr, function (err1, results) {
                    if (!err1) {
                        sucess(results)
                    }
                    else {
                        console.log("操作出错了", err1);
                        fail(err1)
                    }
                })
                // 断开连接
                con.end(function (err1) {
                    if (!err1) {
                        console.log("连接关闭");
                    }
                })
            }
            else {
                console.log("连接出错了", err);
                fail(err)
            }
        })
    }
}